package com.dhl.rabbitmq.eight;

import com.dhl.rabbitmq.utils.RabbitUtils;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;

import java.nio.charset.StandardCharsets;

import static com.dhl.rabbitmq.utils.RabbitConstant.NORMAL_ROUTING_KEY;

/**
 * @author danghailiang
 * 死信实战 生产者
 */
public class DeadProducer {
    public static void main(String[] args) throws Exception {
        // 获取信道
        Channel channel = RabbitUtils.getChannel();
        /**
         * 设置消息属性
         * expiration：过去时间，单位毫秒(可以在消费者方声明队列是设置)
         * 测试最大长度时候注释时间限制
         */
        // AMQP.BasicProperties props = new AMQP.BasicProperties().builder().expiration("20000").build();
        for (int i = 1; i < 11; i++) {
            String message = "info: " + i;
            // 发送消息
            channel.basicPublish(Consumer01.NORMAL_EXCHANGE, NORMAL_ROUTING_KEY,
                    null,
                    message.getBytes(StandardCharsets.UTF_8));
        }
    }
}
